//package com.eastfair.auth.rocketmq;
//
//import com.alibaba.fastjson.JSON;
//import com.eastfair.mq.model.MySimpleMessage;
//import com.eastfair.mq.service.BusinessPointService;
//import com.eastfair.mq.util.MessageExtUtil;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.ConsumeMode;
//import org.apache.rocketmq.spring.annotation.MessageModel;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * @Description: 单个业务类型发送
// */
//@Slf4j
//@Component
//@RocketMQMessageListener(topic = "${rocketmq.consumer.businessPointTopic}", consumerGroup = "${rocketmq.consumer.businessPointTopicConsumer}",
//        selectorExpression = "${rocketmq.tags}",
//        messageModel = MessageModel.CLUSTERING, consumeMode = ConsumeMode.ORDERLY)
//public class BusinessPointListner implements RocketMQListener<MySimpleMessage> {
//
//    @Autowired
//    private BusinessPointService businessPointService;
//    @Autowired
//    private MessageExtUtil messageExtUtil;
//
//    @Override
//    public void onMessage(MySimpleMessage message) {
//        businessPointService.execute(message);
//    }
//
//}
